package com.kim.ping;


import com.kim.ping.mq.Cosumer;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.exception.MQClientException;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;



@SpringBootApplication
@EnableScheduling
public class PingApplication {



    public static void main(String[] args) throws MQClientException {

        SpringApplication.run(PingApplication.class, args);

        Cosumer cosumer = new Cosumer();
        cosumer.setConsumer(new DefaultMQPushConsumer("consumerGroup1"));
        cosumer.start();

    }





}
